var async=require('async');
var h=require('./helper');

/**
 * queue是一个串行的消息队列，通过限制了worker数量，不再一次性全部执行。
 * 当worker数量不够用时，新加入的任务将会排队等候，直到有新的worker可用。
 *
 * 该函数有多个点可供回调，如worker用完时、无等候任务时、全部执行完时等。
 */
// queue(worker, concurrency)

/**
 * 定义一个queue，设worker数量为2
 */
var q = async.queue(function(task, callback) {
    h.log('worker is processing task: ', task.name);
    task.run(callback);
}, 2);

/**
 * 监听：如果某次push操作后，任务数将达到或超过worker数量时，将调用该函数
 */
q.saturated = function() {
    h.log('all workers to be used');
}

/**
 * 监听：当最后一个任务交给worker时，将调用该函数
 */
q.empty = function() {
    h.log('no more tasks wating');
}

/**
 * 监听：当所有任务都执行完以后，将调用该函数
 */
q.drain = function() {
    h.log('all tasks have been processed');
}

/**
 * 独立加入2个任务
 */
q.push({name:'t1', run: function(cb){
    h.log('t1 is running, waiting tasks: ', q.length());
    setTimeout(function () {
        cb(null,'t1');
    },400);
}}, function(err) {
    h.log('t1 executed');
});
h.log('pushed t1, waiting tasks: ', q.length());

q.push({name:'t2',run: function(cb){
    h.log('t2 is running, waiting tasks: ', q.length());
    setTimeout(function () {
        cb(null,'t2');
    },200);
}}, function(err) {
    h.log('t2 executed');
});
h.log('pushed t2, waiting tasks: ', q.length());